//package com.kafka.service.observer;
//
///**
// * 观察者订阅人对象
// */
//public interface Observer {
//
//    /***
//     * 抽象观察者
//     * 定义了一个update()方法，当被观察者调用notifyObservers()方法时，观察者的update()方法会被回调。
//     * @author jstao
//     *
//     */
//    public void update(String message);
//}
